c552aaa6f1cd83582a61c7f1fd9e146da19c3c8a,spring-web-reactive/src/test/java/org/springframework/rx/io/ByteBufPublisherInputStreamTests.java,ByteBufPublisherInputStreamTests,readSingleByte,#,49

Before Change


	@Test
	public void readSingleByte() throws Exception {
		ByteBuf abc = Unpooled.copiedBuffer(new byte[]{'a', 'b', 'c'});
		ByteBuf def = Unpooled.copiedBuffer(new byte[]{'d', 'e', 'f'});

		queue.putBuffer(abc);
		queue.putBuffer(def);
		queue.complete();

After Change


	@Test
	public void readSingleByte() throws Exception {
		queue.putSignal(new byte[]{'a', 'b', 'c'});
		queue.putSignal(new byte[]{'d', 'e', 'f'});
		queue.complete();